package com.xbongbong.paas.connection.service;

import com.xbongbong.paas.toolbox.exception.XbbException;
import com.xbongbong.pro.connector.pojo.dto.ConnectorHistoryDataInitDTO;
import com.xbongbong.pro.connector.pojo.dto.ConnectorRabbitMqDTO;

/**
 * 连接器
 * 创建时间 2020/12/15 10:48 AM
 * 修改时间 2020/12/15 10:48 AM
 * @author chy
 */
public interface ConnectorService {

    /**
     * 向连接器推数据，feign调用
     * @param connectorRabbitMqDTO
     * @throws XbbException
     * 创建时间 2020/12/28 3:55 PM
     * 修改时间 2020/12/28 3:55 PM
     * @author chy
     */
    void triggerSend(ConnectorRabbitMqDTO connectorRabbitMqDTO) throws XbbException;

    /**
     * 全量拉取数据
     * @param corpid
     * @throws XbbException
     * 创建时间 2020/12/28 3:55 PM
     * 修改时间 2020/12/28 3:55 PM
     * @author chy
     */
    void pullData(String corpid) throws Exception;

    /**
     * 历史数据推到连接器
     * @param corpid
     * @param totalNum
     * @throws XbbException
     * 创建时间 2020/12/28 3:55 PM
     * 修改时间 2020/12/28 3:55 PM
     * @author chy
     */
    void pushData(String corpid, Integer totalNum) throws Exception;
}
